package core.rdd.分区;

import org.apache.spark.Partitioner;

public class MyPartitioner extends Partitioner {
    @Override
    public int numPartitions() {
        return 0;
    }

    @Override
    public int getPartition(Object key) {
        return 0;
    }
}
